package com.czy.controller;

import javax.jms.JMSException;
import javax.jms.TextMessage;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class MsgListener {

	/**
	 * 队列使用默认的监听工厂
	 * 如果我设置false那么在IOC里面有一个默认的DefaultJmsListenerContainerFactory能监听队列
	 * @param textMessage
	 * @throws JMSException
	 */
	@JmsListener(destination="queue-hello")
	public void queue(TextMessage textMessage) throws JMSException {
		System.out.println("queue消费者接受消息：" + textMessage.getText());
	}


	/**
	 * 主题使用自定义的监听工厂
	 * @param textMessage
	 * @throws JMSException
	 */
	@JmsListener(destination="topic-hello",containerFactory="jmsTopicContainerFacotory")
	public void topic(TextMessage textMessage) throws JMSException {
		System.out.println("topic消费者接受消息：" + textMessage.getText());
	}

}
